Node / meshtastic / Meshtastic-Android / files / core / data / src / commonMain / kotlin / org / meshtastic / core / data / manager / SessionWork.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope

Tff7b72import T7ee787kotlinx.coroutines.CoroutineStart

Tff7b72import T7ee787kotlinx.coroutines.Job

Tff7b72import T7ee787org.meshtastic.core.common.util.handledLaunch

Tff7b72import T7ee787org.meshtastic.core.repository.RadioInterfaceService

Tff7b72import T7ee787org.meshtastic.core.repository.RadioSessionContext

T8b949e/**

* Launches deferred [block] without a lease for explicitly trusted work, or acquires a nested lifecycle lease before

* the caller can release its packet lease. The undispatched leased path prevents teardown from racing the coroutine's

* first dispatcher turn. [onRejected] runs only when a non-null [session] can no longer admit work.

*/

Tff7b72internal Tff7b72fun Te6edf3RadioInterfaceServiceTb4b4b4.Td2a8fflaunchSessionWorkTb4b4b4(

Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4,

Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContext?Tb4b4b4,

Te6edf3onRejectedTb4b4b4: Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657Unit Tff7b72= Tb4b4b4{Tb4b4b4}Tb4b4b4,

Te6edf3blockTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,

Tb4b4b4)Tb4b4b4: Te6edf3Job Tff7b72= Tff7b72if Tb4b4b4(Te6edf3session Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{ Te6edf3blockTb4b4b4(Tb4b4b4) Tb4b4b4}

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3handledLaunchTb4b4b4(Te6edf3start Tff7b72= Te6edf3CoroutineStartTb4b4b4.Te6edf3UNDISPATCHEDTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3admitted Tff7b72= Te6edf3runWithSessionLeaseTb4b4b4(Te6edf3sessionTb4b4b4) Tb4b4b4{ Te6edf3blockTb4b4b4(Tb4b4b4) Tb4b4b4}

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3admittedTb4b4b4) Te6edf3onRejectedTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tb4b4b4}